package net.lesscoding.shop.boot.rocketmq.listener;

import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.core.RocketMQListener;

/**
 * @author eleven
 * @date 2024/6/4 20:58
 * @apiNote
 */

//@RocketMQMessageListener(topic = "spring-boot-rocketMq", consumerGroup = "${rocketmq.consumer.group}")
@Slf4j
//@Component
public class ConsumerListener implements RocketMQListener<String> {
    @Override
    public void onMessage(String str) {
        log.info("接收到的消息是: {}", str);
    }
}
